package com.event.ingestion.common;

import org.apache.kafka.clients.consumer.ConsumerRecords;

import java.util.Properties;

/**
 * @author ZzHh
 * @Classname Persistable
 * @Description TODO
 * @Date:2020/06/18 11:36
 * @Create by IntelliJ IDEA
 **/

/**
 * 数据写入Hbase的封装
 */
public interface Persistable {
    void initialize(Properties properties);
    int write(ConsumerRecords<String, String> records) throws Exception;
}
